package com.example.yckjbigdataflink.model;

import java.io.Serializable;

public class OriginalRow implements Serializable {
    public String rowkey;
    public String json_data;

    // 必须有空构造函数和 getter/setter（Flink POJO 规范）
    public OriginalRow() {}

    public OriginalRow(String rowkey, String json_data) {
        this.rowkey = rowkey;
        this.json_data = json_data;
    }

    public String getRowkey() {
        return rowkey;
    }

    public void setRowkey(String rowkey) {
        this.rowkey = rowkey;
    }

    public String getJson_data() {
        return json_data;
    }

    public void setJson_data(String json_data) {
        this.json_data = json_data;
    }

    @Override
    public String toString() {
        return "OriginalRow{" +
                "rowkey='" + rowkey + '\'' +
                ", json_data='" + json_data + '\'' +
                '}';
    }
}

